--[[
    编码: JX-40-12
    名称: 取消作业
    作者: HAN  
    日期：2025-1-29
    
    级别：固定 (说明本段代码在项目中不太会变化)

    函数： OperationCancel

    功能:
        把作业的状态设置为 取消
        -- 需要判断 什么 作业的任务状态
    变更记录:

--]]

jx_api = require ( "jx_external_api")
wms_op = require ( "wms_operation")

function OperationCancel( strLuaDEID )
    local nRet, strRetInfo, operation_objs,n,m

    nRet, operation_objs = m3.GetSysDataJson( strLuaDEID )
    if ( nRet ~=0 ) then lua.Error( strLuaDEID, debug.getinfo(1), objs ) end  

    local nCount = #operation_objs
    if (nCount == 0) then  return end

    local task_objs, wave_obj
    local task_code, cntr_code, task    
    local operation = {}
    local strCondition
    local prompt_msg, msg, can_cancel
    local cancel_count = 0                  -- 取消作业数量

    prompt_msg = ''
    for n = 1, nCount do
        nRet, operation = m3.ObjAttrStrToLuaObj( "Operation", lua.table2str(operation_objs[n].attrs) )
        if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "m3.ObjAttrStrToLuaObj 失败! "..operation ) end

        -- 只要是作业没完成的都可以取消 N_B_STATE = 2 (完成) 并且作业的任务状态（N_TASK_STATE） 不等于 2
        -- 作业的任务状态=2 表示作业下面的任务已经设备开始执行了，这个时候必须和设备端进行一些交互后才能取消
        if ( operation.bs_state ~= 2 and operation.task_state ~= 2 ) then
            can_cancel = true
            -- 查询作业下面的任务（状态 = 0等待 1已推送） 
            strCondition = "S_OP_CODE = '"..operation.code.."' AND ( N_B_STATE = 0 OR N_B_STATE = 1 )  "
            nRet, task_objs = m3.QueryDataObject(strLuaDEID, "Task",  strCondition)
            if (nRet ~= 0) then
                lua.Error(strLuaDEID, debug.getinfo(1), "获取任务信息失败!" .. operation.code)
            end
            if (task_objs ~= '') then
                for m = 1, #task_objs do
                    task = m3.KeyValueAttrsToObjAttr( task_objs[m].attrs )
                    task_code = lua.Get_StrAttrValue( task.S_CODE )
                    cntr_code = lua.Get_StrAttrValue( task.S_CNTR_CODE )

                    if ( lua.Get_NumAttrValue( task.N_B_STATE ) == 1 ) then
                        -- 1 任务已经已经推送给WCS，因此需要调用WCS接口进行取消
                        nRet, strRetInfo = jx_api.WCS_Cancel( strLuaDEID, cntr_code, task_code ) 
                        if ( nRet ~= 0 ) then
                            msg = "编号 = '"..operation.code.."'的作业无法取消, 原因是WCS无法取消料箱号 = "..cntr_code.." 的任! 原因:"..strRetInfo
                            prompt_msg = prompt_msg..msg.."\r\n"
                            can_cancel = false
                        end
                    end
                end
            end

            if ( can_cancel ) then
                -- 把作业下面的‘待启动’，‘已推送’任务的状态设置为 5/取消
                strCondition = "S_OP_CODE = '"..operation.code.."' AND ( N_B_STATE = 0 OR N_B_STATE = 1 )  "
                strUpdateSql = "N_B_STATE = 5"
                nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Task", strCondition, strUpdateSql )
                if ( nRet ~= 0 ) then  
                    lua.Error( strLuaDEID, debug.getinfo(1), "更新【Task】信息失败!"..strRetInfo ) 
                end     

                nRet, strRetInfo = wms_op.SetCancel( strLuaDEID, operation )
                if ( nRet ~= 0 ) then  
                    lua.Error( strLuaDEID, debug.getinfo(1), "更新【Operation】信息失败!"..strRetInfo ) 
                end    
                
                -- 检查作业来源，如果是入库波次，出库波次，他们的状态是关闭中 需要触发后台进行 强制完成操作
                if ( operation.bs_type == "Inbound_Wave" ) then 
                    nRet, wave_obj = m3.GetDataObjectByKey(strLuaDEID, operation.bs_type, "S_WAVE_NO", operation.bs_no )
                    if (nRet ~= 0 ) then 
                        lua.Error( strLuaDEID, debug.getinfo(1), "获取'"..operation.bs_type.."'信息失败! " .. wave_obj ) 
                    end                    
                    -- 如果入库波次状态=6/关闭中，需要后台触发强制完成事件
                    if ( wave_obj.b_state == 6 ) then
                        local add_wfp = {
                            wfp_type = 1,                  -- 触发数据对象事件（指定数据对象标识）
                            cls = "Inbound_Wave",
                            obj_id = wave_obj.id,
                            obj_name = "入库波次号'"..operation.bs_no.."'-->强制完成",
                            trigger_event = "强制完成"
                        }
                        nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp )
                        if ( nRet ~= 0 ) then 
                            lua.Error( strLuaDEID, debug.getinfo(1), "AddSysWFP失败!"..strRetInfo )  
                        end                        
                    end
                elseif ( operation.bs_type == "Outbound_Wave" ) then 
                    nRet, wave_obj = m3.GetDataObjectByKey(strLuaDEID, operation.bs_type, "S_WAVE_NO", operation.bs_no )
                    if (nRet ~= 0 ) then 
                        lua.Error( strLuaDEID, debug.getinfo(1), "获取'"..operation.bs_type.."'信息失败! " .. wave_obj ) 
                    end                    
                    -- 如果出库波次状态 = 8/关闭中，需要后台触发强制完成事件
                    if ( wave_obj.b_state == 8 ) then
                        local add_wfp = {
                            wfp_type = 1,                  -- 触发数据对象事件（指定数据对象标识）
                            cls = "Outbound_Wave",
                            obj_id = wave_obj.id,
                            obj_name = "出库波次号'"..operation.bs_no.."'-->强制完成",
                            trigger_event = "强制完成"
                        }
                        nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp )
                        if ( nRet ~= 0 ) then 
                            lua.Error( strLuaDEID, debug.getinfo(1), "AddSysWFP失败!"..strRetInfo )  
                        end                        
                    end
                end
                cancel_count = cancel_count + 1
            end
        end
    end

    -- 如果中间有作业无法取消的，前端显示原因
    if ( prompt_msg ~= '' ) then
        mobox.setInfo( strLuaDEID, prompt_msg )
    end
    local action
    if ( cancel_count == 1 ) then
        action = {
                    {
                        action_type = "refresh_cur_row",
                        value = ""
                    }
                }
    else
        action = {
            {
                action_type = "refresh",
                value = ""
            }
        }        
    end
    nRet, strRetInfo = mobox.setAction(strLuaDEID, lua.table2str(action))
    if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "setAction错误: "..strRetInfo) end      

end